package com.enjoyor.soa.traffic.frame.support.kafka.message;

import java.io.Serializable;
import java.util.Date;

public class KafkaMessageHeader implements Serializable, Cloneable {

    /**
     * 
     */
    private static final long serialVersionUID = -4610291260707731233L;

    // 消息惟一标识
    private String serialNo;

    // 消息来自不同系统区分
    private String systemSource;

    // 创建时间
    private Date createTime;

    // 消息类型，用于区分不同业务消息
    private String messageType;

    public KafkaMessageHeader() {
    }

    public KafkaMessageHeader(String serialNo, String systemSource, Date createTime, String messageType) {
        this.serialNo = serialNo;
        this.systemSource = systemSource;
        this.createTime = createTime;
        this.messageType = messageType;
    }

    public String getSerialNo() {
        return serialNo;
    }

    public void setSerialNo(String serialNo) {
        this.serialNo = serialNo;
    }

    public String getSystemSource() {
        return systemSource;
    }

    public void setSystemSource(String systemSource) {
        this.systemSource = systemSource;
    }

    public Date getCreateTime() {
        return createTime;
    }

    public void setCreateTime(Date createTime) {
        this.createTime = createTime;
    }

    public String getMessageType() {
        return messageType;
    }

    public void setMessageType(String messageType) {
        this.messageType = messageType;
    }

}
